package com.trainoo.config;

import lombok.Data;

/**
 * <p> rocket配置 </p>
 *
 * @author tao.zhou
 * @version 1.0
 * @date 2020/6/28 09:53
 */
@Data
public class RocketMQProperties {

    private boolean isEnable = false;
    private String namesrvAddr = "10.13.0.94:9876";
    private String groupName = "default";
    private int producerMaxMessageSize = 1024;
    private int producerSendMsgTimeout = 2000;
    private int producerRetryTimesWhenSendFailed = 2;
    private int consumerConsumeThreadMin = 5;
    private int consumerConsumeThreadMax = 30;
    private int consumerConsumeMessageBatchMaxSize = 1;

}
